package com.birdy.mq;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.LitePullConsumer;
import org.apache.rocketmq.client.consumer.MQConsumer;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.MQProducer;

/**
 * @author birdy
 * @date 2022/4/6 4:04 PM
 */
public interface MqFactory {
    MQProducer getProducer() throws MQClientException;
    LitePullConsumer getLitePullConsumer();
    DefaultMQPushConsumer getPushConsumer();
}
